import requests
import json


def send_chat_message(session_id, message):
    """
    发送聊天消息到后端接口
    参数:
        session_id: 会话ID
        message: 要发送的消息内容
    返回:
        接口响应数据或None（发生错误时）
    """
    # 接口URL
    url = "http://localhost:8001/api/chat/send"

    # 请求头
    headers = {
        "Content-Type": "application/json"
    }

    # 请求体数据
    payload = {
        "message": message,
        "session_id": session_id
    }

    try:
        # 发送POST请求
        response = requests.post(
            url,
            headers=headers,
            data=json.dumps(payload),
            timeout=100
        )

        # 检查响应状态码
        if response.status_code == 200:
            print("[消息发送] ✅ 消息发送成功")
            return response.json()
        else:
            print(f"[消息发送] ❌ 接口返回错误状态码: {response.status_code}")
            print(f"[消息发送] 响应内容: {response.text}")
            return None

    except requests.exceptions.RequestException as e:
        print(f"[消息发送] ❌ 请求发生错误: {str(e)}")
        return None


if __name__ == "__main__":
    # 示例会话ID和消息
    session_id = "19aecbcc-07ab-40e0-bddb-73b87cd58380"
    message = "你是谁？"

    # 发送消息
    print(f"[消息发送] 准备发送消息: {message}")
    print(f"[消息发送] 使用会话ID: {session_id}")

    response_data = send_chat_message(session_id, message)

    # 打印响应结果
    if response_data:
        print("\n[响应结果] 接口返回数据:")
        print(json.dumps(response_data, indent=2, ensure_ascii=False))
